# 进程间通信 通过队列 queue
from multiprocessing import Queue

q = Queue(5)
q.put('A')
q.put('B')
q.put('C')
q.put('D')
q.put('E')

print(q.qsize())

if not q.full():
    q.put('F', timeout=1)  # 如果queue满了 需要阻塞等待
else:
    print('队列已满')

while True:
    if q.empty():
        print('队列已空')
        break
    print(q.get())  # 如果queue空了 需要阻塞等待
